package com.ltsh.fim.common.model;

import java.util.concurrent.ConcurrentHashMap;

public class FimRequestHolder {

    // key: requestId     value: RpcFuture
    private static ConcurrentHashMap<String,FimFuture> processingRpc = new ConcurrentHashMap<>();

    public static void put(String requestId,FimFuture fimFuture){
        processingRpc.put(requestId, fimFuture);
    }

    public static FimFuture get(String requestId){
        return processingRpc.get(requestId);
    }

    public static void remove(String requestId){
        processingRpc.remove(requestId);
    }
}
